package kafka_go

//消费者返回数据监听
type ConsumerResponseListener func(context *ConsumerMessageContext)
